package com.company;

public class Consumer extends BaseThread{

    public Consumer(String threadName, MutiBufferQueue queue) {
        super(threadName, queue);
    }

    @Override
    public void run() {
        try {
            while (true){
                Object obj = this.mQueue.take();
                if(null == obj){
                    System.out.println(this.mQueue);
                }
                Thread.sleep(0);
            }
        }
        catch (InterruptedException e){

        }

    }
}
